/*
 * CustomNameThreadFactory.java    ver   23/nov/2009
 *
 * Copyright (c) 2009 mentalsmash.org
 * 
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 *
 * The use of the Apache License does not indicate that this project is
 * affiliated with the Apache Software Foundation.
 */
package org.mentalsmash.tazio.transactions.util;

import java.util.concurrent.Executors;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.atomic.AtomicInteger;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * Provides an implementation of {@link ThreadFactory} to be used when you need
 * to specify names different from the defaults of the
 * {@link Executors#defaultThreadFactory()} ThreadFactory.
 * <p>
 * It containes an internal counter and sets the name of the created threads to
 * prefix-<code>counterValue</code>.
 * </p>
 * 
 * @version 0.0.1 23/nov/2009
 * @author Andrea Reale <andrea.reale@gmail.com>
 * 
 */
public class CustomNameThreadFactory implements ThreadFactory {

    private final static Logger log = LoggerFactory
	    .getLogger(CustomNameThreadFactory.class);

    private String prefix = "pool-thread";
    private final AtomicInteger seq = new AtomicInteger(0);
    private final ThreadFactory impl = Executors.defaultThreadFactory();

    public CustomNameThreadFactory(final String prefix) {
	if (prefix == null) {
	    log.warn("Null prefix, using the default");
	}
	this.prefix = prefix;
    }

    @Override
    public Thread newThread(final Runnable r) {
	final Thread t = impl.newThread(r);
	t.setName(prefix + "-" + seq.getAndIncrement());

	return t;
    }

}
